package cn.smileyan.demos.entity;

import cn.smileyan.demos.core.CountTrigger;
import lombok.Data;

/**
 * kafka 接收数据
 * @author smileyan
 */
@Data
public class TaskInput implements CountTrigger {
    /**
     * 任务编号
     */
    private String taskId;

    /**
     * 集群编号
     */
    private String clusterId;

    /**
     * 结点编号（机器编号）
     */
    private String itemId;

    /**
     * 集群大小
     */
    private Integer clusterSize;

    /**
     * 集群中当前任务索引
     */
    private Integer currentIndex;

    /**
     * 样本数据
     */
    private Point data;

    /**
     * 阈值配置
     */
    private ThresholdConfig thresholdConfig;

    @Override
    public int triggerSize() {
        return clusterSize;
    }

    @Override
    public String triggerId() {
        return taskId;
    }
}
